﻿using DotNetCore.CAP;
using MediatR;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace UnitOfWorkCore.IntegrationEvents
{
    public class SubscriberService : ICapSubscribe
    {
        public SubscriberService()
        {

        }

        [CapSubscribe("user.created")]
        public async Task UserCreated(UserCreatedEvent @event)
        {
            //await Task.Delay(20000);
            //throw new Exception();
            Console.WriteLine();
        }
    }
}
